package com.wm.wmim.server.rpc.impl;

import com.wm.wmim.common.dto.RpcRespDTO;
import com.wm.wmim.connect.sdk.onmessage.bo.resp.SendMessageCommonRespBO;
import com.wm.wmim.connect.sdk.onmessage.rpc.OnMessageRpcService;
import org.apache.dubbo.config.annotation.DubboService;

import java.util.Map;

/**
 * @author weiming
 * @date 2024/12/22 15:37
 * @description
 */
@DubboService(version = "1.0.0", group = "common")
public class CommonOnMessageRpcServiceImpl implements OnMessageRpcService {
    @Override
    public RpcRespDTO<SendMessageCommonRespBO> onMessage(Map<String, Object> attributes, String message) {
        SendMessageCommonRespBO common = SendMessageCommonRespBO.builder().push(true).message("common").build();
        return RpcRespDTO.buildSuccess(common);
    }
}
